package org.apache.servicecomb.fence.resource.mapper;

import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.apache.servicecomb.fence.api.resource.RocketMqMsg;

@Mapper
public interface RocketMqMsgMapper {
    @Select("""
            select ID, MSGID, TOPIC, MSGINFO from rocket_mq_msg where MSGID=#{msgId};
      """)
    RocketMqMsg getMsgByMsgId(@Param("msgId") String msgId);


    @Insert("""
      insert into
      rocket_mq_msg(MSGID,TOPIC,MSGINFO)
      values(#{msgId},#{topic},#{msgInfo})
      """)
    int insert(@Param("msgId") String msgId,
                        @Param("topic") String topic,
                        @Param("msgInfo") String msgInfo);


}
